package com.sunsys.mapreduce.reducer.side.outer.join;

import java.io.IOException;

import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;
import org.apache.hadoop.mapreduce.lib.input.FileSplit;

public class OuterJoinMapper extends Mapper<LongWritable, Text, Text, Text> {

	private String fileName = null;
	
	public OuterJoinMapper() {
	}
	
	@Override
	protected void setup(Mapper<LongWritable, Text, Text, Text>.Context context) throws IOException, InterruptedException {
		FileSplit fileSplit = (FileSplit)context.getInputSplit();
		Path  filePaht = fileSplit.getPath();
		fileName = filePaht.getName();
	}
	
	@Override
	protected void map(LongWritable key, Text value, Mapper<LongWritable, Text, Text, Text>.Context context) throws IOException, InterruptedException {
//		value.set
	}
	
}
